package com.zr.rocketmq.producer;

import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.Map;

@Service
public class OrderService {
    // 模拟数据库存储订单
    private static final Map<String, String> ORDER_STATUS_MAP = new HashMap<>();

    /**
     * 执行本地事务：创建订单
     */
    public boolean createOrder(String orderId) {
        try {
            // 模拟订单创建逻辑
            ORDER_STATUS_MAP.put(orderId, "CREATED");
            System.out.println("本地事务执行：创建订单成功，订单ID: " + orderId);
            return true;
        } catch (Exception e) {
            System.out.println("本地事务执行：创建订单失败，订单ID: " + orderId);
            return false;
        }
    }

    /**
     * 事务回查：查询订单状态
     */
    public String getOrderStatus(String orderId) {
        return ORDER_STATUS_MAP.getOrDefault(orderId, "NOT_EXIST");
    }
}
